package com.example.streamkafka.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * describe:
 *
 * @author helloworldyu
 * @date 2018/6/26
 */
public interface Sink {
	String INPUT = "channel_in";

	@Input(Sink.INPUT)
	SubscribableChannel input();
}
